package com.sui.bigdata.rtcadmin.constant;

/**
 * @author YongChen
 * @date 2019/12/2 10:53
 * @description
 * @email yong_chen@sui.com
 */
public class JobConstant {
    public final static String SUBMIT = "submit";
    public final static String RESTART = "restart";
    public final static String STOP = "stop";
    public final static String RESTARTALL = "restartAll";


    public final static String APP_ID = "appId";
    public final static String JOB_ID = "jobId";
    public final static String WEB_URL = "webUrl";
    public final static String ERROR_MSG = "errorMsg";

    public final static String PARALLELISM = "parallelism";
    public final static String QUEUE = "queue";
    public final static String TASK_MANAGER_MEMORY_MB = "taskManagerMemoryMb";
    public final static String TASK_MANAGER_SLOTS = "taskManagerSlots";
    public final static String JOB_MANAGER_MEMORY_MB = "jobManagerMemoryMb";

    public final static String RUNNING = "RUNNING";
    public final static String ACCEPT = "ACCEPT";
    public final static String EDITED = "EDITED";
    public final static String CANCELED = "CANCELED";
    public final static String INITIALIZING = "INITIALIZING";
    // 当任务重启三次之后会进入该状态：HANG
    public final static String HANG = "HANG";

    public final static String FLINK_WEB_SUFFIX = "/#/overview";
    public final static String FLINK_WEB_PREFIX = "flink.web.prefix";

    public final static String KAFKA_BROKERS = "kafka.bootstrap.servers";
    public static final String KAFKA_TOPIC= "kafka.topic";
    public static final String KAFKA_GROUP_ID = "kafka.group.id";
    public static final String KAFKA_POLL_TIMEOUT = "kafka.consumer.poll.timeout";
    public static final String KAFKA_AUTO_COMMIT = "kafka.consumer.auto.commit";
    public static final String KAFKA_CONCURRENCY = "kafka.consumer.concurrency";
    public static final String KAFKA_MAX_POLL_RECORDS = "kafka.max.poll.records";


    public static final String KAFKA = "kafka";
    public static final String SQL_SELECT_SINK = "sql.select.sink";
    public static final String SQL_SELECT_KAFKA_BROKERS = "sql.select.kafka.bootstrap";
    public static final String SQL_SELECT_KAFKA_TOPIC =  "sql.select.kafka.topic";

    public static final String ENGINE_FLINK = "flink";
    public static final String ENGINE_SPARK = "spark";


    public static final String SQL_SOURCE_COMPONENT =  "sql.source.component";
    public static final String SQL_SIDE_COMPONENT =  "sql.side.component";
    public static final String SQL_SINK_COMPONENT =  "sql.sink.component";

    public static final int JOB_IS_ONLINE =  1;
    public static final int JOB_ONT_ONLINE =  0;





}
